
package com.kweative.cluster;

import com.kweative.util.KClassLoader;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.ObjectStreamClass;

/**
 *
 * @author henrik
 */
public class ClusterInputStream extends ObjectInputStream {

    public ClusterInputStream(InputStream in) throws IOException {
        super(in);
    }

    @Override
    protected Class<?> resolveClass(ObjectStreamClass osc) throws IOException, ClassNotFoundException {
        return Class.forName(osc.getName(), false,KClassLoader.getClassLoader());
    }
}
